#ifndef __MSGQUEUE_H__
#define __MSGQUEUE_H__

#include "env.h"
#include "msghandle.h"

namespace WServer {
namespace MsgQueue {
void wserInitMsgQueue(int mindex);
void wserUninitMsgQueue();

extern std::list<MsgHandle::wmsgdata*> clientmsglist;
extern std::vector<std::deque<MsgHandle::wmsgdata*> > servermsglist;

extern void PushStream(int index, void* p, int len, int from, int to);
extern boost::tuple<int, void*, int> PopStream(int inc);
extern MsgHandle::wmsgdata* PopMessage(int inc);
}
}

#endif //__MSGQUEUE_H__
